package com.gemframe.kafka;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;

public interface Sink {
	
	//接收队列1
	String INPUT_1 = "acceptLogs";
 
	@Input(Sink.INPUT_1)
	SubscribableChannel input1();
 
}
